package com.wjy.common.mq.ps;

import lombok.extern.log4j.Log4j2;
import org.springframework.stereotype.Component;
import redis.clients.jedis.JedisPubSub;

/**
 * 订阅者/发布者 监听
 */
@Log4j2
@Component
public class JedisPubSubListener extends JedisPubSub {

    @Override
    public void onMessage(String channel, String message) {
        log.info("频道：" + channel + " 订阅消息：" + message);
    }

}
